--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
meshchatx/src/backend/voicemail_manager.py fda9187e95d8b9cc8373c1de23cefce6928c241d (fda9187e) Text, 23.55 KB
Tff7b72import T7ee787os
Tff7b72import T7ee787platform
Tff7b72import T7ee787shutil
Tff7b72import T7ee787subprocess
Tff7b72import T7ee787sys
Tff7b72import T7ee787threading
Tff7b72import T7ee787time
Tff7b72import T7ee787LXST
Tff7b72import T7ee787RNS
Tff7b72from T7ee787LXSTT7ee787.T7ee787Codecs Tff7b72import Te6edf3Null
Tff7b72from T7ee787LXSTT7ee787.T7ee787Pipeline Tff7b72import Te6edf3Pipeline
Tff7b72from T7ee787LXSTT7ee787.T7ee787Sinks Tff7b72import Te6edf3OpusFileSink
Tff7b72from T7ee787LXSTT7ee787.T7ee787Sources Tff7b72import Te6edf3OpusFileSource
Tff7b72class T56d364VoicemailManagerTb4b4b4:
Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3dbTb4b4b4, Te6edf3configTb4b4b4, Te6edf3telephone_managerTb4b4b4, Te6edf3storage_dirTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffdb Tff7b72= Te6edf3db
Tff7b72selfTff7b72.Td2a8ffconfig Tff7b72= Te6edf3config
Tff7b72selfTff7b72.Td2a8fftelephone_manager Tff7b72= Te6edf3telephone_manager
Tff7b72selfTff7b72.Td2a8ffstorage_dir Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Te6edf3storage_dirTb4b4b4, Ta5d6ff"Ta5d6ffvoicemailsTa5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffgreetings_dir Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstorage_dirTb4b4b4, Ta5d6ff"Ta5d6ffgreetingsTa5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffrecordings_dir Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstorage_dirTb4b4b4, Ta5d6ff"Ta5d6ffrecordingsTa5d6ff"Tb4b4b4)
T8b949e# Ensure directories exist
Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Te6edf3exist_okTff7b72=Tff7b72TrueTb4b4b4)
Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrecordings_dirTb4b4b4, Te6edf3exist_okTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffis_recording Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ffis_greeting_recording Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ffrecording_pipeline Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_sink Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_start_time Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_remote_identity Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_filename Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffon_new_voicemail_callback Tff7b72= Tff7b72None
T8b949e# stabilization delay for voicemail greeting
Tff7b72selfTff7b72.Td2a8ffSTABILIZATION_DELAY Tff7b72= T79c0ff1.0
T8b949e# Paths to executables
Tff7b72selfTff7b72.Td2a8ffespeak_path Tff7b72= Tff7b72selfTff7b72.Td2a8ff_find_espeakTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffffmpeg_path Tff7b72= Tff7b72selfTff7b72.Td2a8ff_find_ffmpegTb4b4b4(Tb4b4b4)
T8b949e# Check for presence
Tff7b72selfTff7b72.Td2a8ffhas_espeak Tff7b72= Tff7b72selfTff7b72.Td2a8ffespeak_path Tff7b72is Tff7b72not Tff7b72None
Tff7b72selfTff7b72.Td2a8ffhas_ffmpeg Tff7b72= Tff7b72selfTff7b72.Td2a8ffffmpeg_path Tff7b72is Tff7b72not Tff7b72None
Tff7b72if Tff7b72selfTff7b72.Td2a8ffhas_espeakTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Found eSpeak at Tffd700{Tff7b72selfTff7b72.Td2a8ffespeak_pathTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: eSpeak not foundTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffhas_ffmpegTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Found ffmpeg at Tffd700{Tff7b72selfTff7b72.Td2a8ffffmpeg_pathTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: ffmpeg not foundTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72def Td2a8ffget_name_for_identity_hashTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_hashTb4b4b4)Tb4b4b4:
T8b949e"""Default implementation, should be patched by ReticulumMeshChat"""
Tff7b72return
Tff7b72def Td2a8ff_find_bundled_binaryTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3nameTb4b4b4)Tb4b4b4:
Tff7b72if Tffa657getattrTb4b4b4(Te6edf3sysTb4b4b4, Ta5d6ff"Ta5d6fffrozenTa5d6ff"Tb4b4b4, Tff7b72FalseTb4b4b4)Tb4b4b4:
Te6edf3exe_dir Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffdirnameTb4b4b4(Te6edf3sysTff7b72.Td2a8ffexecutableTb4b4b4)
T8b949e# Try in bin/ subdirectory of the executable
Te6edf3local_bin Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Te6edf3exe_dirTb4b4b4, Ta5d6ff"Ta5d6ffbinTa5d6ff"Tb4b4b4, Te6edf3nameTb4b4b4)
Tff7b72if Te6edf3platformTff7b72.Td2a8ffsystemTb4b4b4(Tb4b4b4) Tff7b72== Ta5d6ff"Ta5d6ffWindowsTa5d6ff"Tb4b4b4:
Te6edf3local_bin Tff7b72+Tff7b72= Ta5d6ff"Ta5d6ff.exeTa5d6ff"
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3local_binTb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3local_bin
T8b949e# Try in executable directory itself
Te6edf3local_bin Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Te6edf3exe_dirTb4b4b4, Te6edf3nameTb4b4b4)
Tff7b72if Te6edf3platformTff7b72.Td2a8ffsystemTb4b4b4(Tb4b4b4) Tff7b72== Ta5d6ff"Ta5d6ffWindowsTa5d6ff"Tb4b4b4:
Te6edf3local_bin Tff7b72+Tff7b72= Ta5d6ff"Ta5d6ff.exeTa5d6ff"
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3local_binTb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3local_bin
Tff7b72return Tff7b72None
Tff7b72def Td2a8ff_find_espeakTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
T8b949e# Try bundled first
Te6edf3bundled Tff7b72= Tff7b72selfTff7b72.Td2a8ff_find_bundled_binaryTb4b4b4(Ta5d6ff"Ta5d6ffespeak-ngTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3bundledTb4b4b4:
Tff7b72return Te6edf3bundled
Te6edf3bundled Tff7b72= Tff7b72selfTff7b72.Td2a8ff_find_bundled_binaryTb4b4b4(Ta5d6ff"Ta5d6ffespeakTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3bundledTb4b4b4:
Tff7b72return Te6edf3bundled
T8b949e# Try standard name first
Te6edf3path Tff7b72= Te6edf3shutilTff7b72.Td2a8ffwhichTb4b4b4(Ta5d6ff"Ta5d6ffespeak-ngTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3pathTb4b4b4:
Tff7b72return Te6edf3path
T8b949e# Try without -ng suffix
Te6edf3path Tff7b72= Te6edf3shutilTff7b72.Td2a8ffwhichTb4b4b4(Ta5d6ff"Ta5d6ffespeakTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3pathTb4b4b4:
Tff7b72return Te6edf3path
T8b949e# Windows common install locations if not in PATH
Tff7b72if Te6edf3platformTff7b72.Td2a8ffsystemTb4b4b4(Tb4b4b4) Tff7b72== Ta5d6ff"Ta5d6ffWindowsTa5d6ff"Tb4b4b4:
Te6edf3common_paths Tff7b72= Tb4b4b4[
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexpandvarsTb4b4b4(Ta5d6ffrTa5d6ff"Ta5d6ff%Ta5d6ffProgramFilesTa5d6ff%Ta5d6ff\Ta5d6ffeSpeak NGTa5d6ff\Ta5d6ffespeak-ng.exeTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexpandvarsTb4b4b4(Ta5d6ffrTa5d6ff"Ta5d6ff%Ta5d6ffProgramFiles(x86)Ta5d6ff%Ta5d6ff\Ta5d6ffeSpeak NGTa5d6ff\Ta5d6ffespeak-ng.exeTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexpandvarsTb4b4b4(Ta5d6ffrTa5d6ff"Ta5d6ff%Ta5d6ffProgramFilesTa5d6ff%Ta5d6ff\Ta5d6ffeSpeakTa5d6ff\Ta5d6ffespeak.exeTa5d6ff"Tb4b4b4)Tb4b4b4,
Tb4b4b4]
Tff7b72for Te6edf3p Tff7b72in Te6edf3common_pathsTb4b4b4:
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3pTb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3p
Tff7b72return Tff7b72None
Tff7b72def Td2a8ff_find_ffmpegTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
T8b949e# Try bundled first
Te6edf3bundled Tff7b72= Tff7b72selfTff7b72.Td2a8ff_find_bundled_binaryTb4b4b4(Ta5d6ff"Ta5d6ffffmpegTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3bundledTb4b4b4:
Tff7b72return Te6edf3bundled
Te6edf3path Tff7b72= Te6edf3shutilTff7b72.Td2a8ffwhichTb4b4b4(Ta5d6ff"Ta5d6ffffmpegTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3pathTb4b4b4:
Tff7b72return Te6edf3path
T8b949e# Windows common install locations
Tff7b72if Te6edf3platformTff7b72.Td2a8ffsystemTb4b4b4(Tb4b4b4) Tff7b72== Ta5d6ff"Ta5d6ffWindowsTa5d6ff"Tb4b4b4:
Te6edf3common_paths Tff7b72= Tb4b4b4[
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexpandvarsTb4b4b4(Ta5d6ffrTa5d6ff"Ta5d6ff%Ta5d6ffProgramFilesTa5d6ff%Ta5d6ff\Ta5d6ffffmpegTa5d6ff\Ta5d6ffbinTa5d6ff\Ta5d6ffffmpeg.exeTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexpandvarsTb4b4b4(Ta5d6ffrTa5d6ff"Ta5d6ff%Ta5d6ffProgramFiles(x86)Ta5d6ff%Ta5d6ff\Ta5d6ffffmpegTa5d6ff\Ta5d6ffbinTa5d6ff\Ta5d6ffffmpeg.exeTa5d6ff"Tb4b4b4)Tb4b4b4,
Tb4b4b4]
Tff7b72for Te6edf3p Tff7b72in Te6edf3common_pathsTb4b4b4:
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3pTb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3p
Tff7b72return Tff7b72None
Tff7b72def Td2a8ffgenerate_greetingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3textTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffhas_espeak Tff7b72or Tff7b72not Tff7b72selfTff7b72.Td2a8ffhas_ffmpegTb4b4b4:
Te6edf3msg Tff7b72= Ta5d6ff"Ta5d6ffespeak-ng and ffmpeg are required for greeting generationTa5d6ff"
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Te6edf3msgTb4b4b4)
Te6edf3wav_path Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Ta5d6ff"Ta5d6ffgreeting.wavTa5d6ff"Tb4b4b4)
Tff7b72tryTb4b4b4:
T8b949e# espeak-ng to WAV with improved parameters
Te6edf3speed Tff7b72= Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_tts_speedTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3pitch Tff7b72= Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_tts_pitchTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3voice Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_tts_voiceTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)
Te6edf3gap Tff7b72= Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_tts_word_gapTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3cmd Tff7b72= Tb4b4b4[
Tff7b72selfTff7b72.Td2a8ffespeak_pathTb4b4b4,
Ta5d6ff"Ta5d6ff-sTa5d6ff"Tb4b4b4,
Te6edf3speedTb4b4b4,
Ta5d6ff"Ta5d6ff-pTa5d6ff"Tb4b4b4,
Te6edf3pitchTb4b4b4,
Ta5d6ff"Ta5d6ff-gTa5d6ff"Tb4b4b4,
Te6edf3gapTb4b4b4,
Ta5d6ff"Ta5d6ff-kTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff10Ta5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-vTa5d6ff"Tb4b4b4,
Te6edf3voiceTb4b4b4,
Ta5d6ff"Ta5d6ff-wTa5d6ff"Tb4b4b4,
Te6edf3wav_pathTb4b4b4,
Te6edf3textTb4b4b4,
Tb4b4b4]
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Generating greeting with command: Tffd700{Ta5d6ff'Ta5d6ff Ta5d6ff'Tff7b72.Td2a8ffjoinTb4b4b4(Te6edf3cmdTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Te6edf3subprocessTff7b72.Td2a8ffrunTb4b4b4(Te6edf3cmdTb4b4b4, Te6edf3checkTff7b72=Tff7b72TrueTb4b4b4) T8b949e# noqa: S603
T8b949e# Convert WAV to Opus
Tff7b72return Tff7b72selfTff7b72.Td2a8ffconvert_to_greetingTb4b4b4(Te6edf3wav_pathTb4b4b4)
Tff7b72finallyTb4b4b4:
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3wav_pathTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3wav_pathTb4b4b4)
Tff7b72def Td2a8ffconvert_to_greetingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3input_pathTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffhas_ffmpegTb4b4b4:
Te6edf3msg Tff7b72= Ta5d6ff"Ta5d6ffffmpeg is required for audio conversionTa5d6ff"
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Te6edf3msgTb4b4b4)
Te6edf3opus_path Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Ta5d6ff"Ta5d6ffgreeting.opusTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3opus_pathTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3opus_pathTb4b4b4)
Te6edf3subprocessTff7b72.Td2a8ffrunTb4b4b4( T8b949e# noqa: S603
Tb4b4b4[
Tff7b72selfTff7b72.Td2a8ffffmpeg_pathTb4b4b4,
Ta5d6ff"Ta5d6ff-iTa5d6ff"Tb4b4b4,
Te6edf3input_pathTb4b4b4,
Ta5d6ff"Ta5d6ff-c:aTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6fflibopusTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-b:aTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff16kTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-arTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff48000Ta5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-acTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff1Ta5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-vbrTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ffonTa5d6ff"Tb4b4b4,
Te6edf3opus_pathTb4b4b4,
Tb4b4b4]Tb4b4b4,
Te6edf3checkTff7b72=Tff7b72TrueTb4b4b4,
Tb4b4b4)
Tff7b72return Te6edf3opus_path
Tff7b72def Td2a8ffremove_greetingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3opus_path Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Ta5d6ff"Ta5d6ffgreeting.opusTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3opus_pathTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3opus_pathTb4b4b4)
Tff7b72return Tff7b72True
Tff7b72def Td2a8ffhandle_incoming_callTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3caller_identityTb4b4b4)Tb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: handle_incoming_call from Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3caller_identityTff7b72.Td2a8ffhashTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_enabledTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: Voicemail is disabledTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)
Tff7b72return
Te6edf3delay Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_auto_answer_delay_secondsTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Will auto-answer in Tffd700{Te6edf3delayTffd700}Ta5d6ff secondsTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)
Tff7b72def Td2a8ffvoicemail_jobTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Auto-answer timer started for Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3caller_identityTff7b72.Td2a8ffhashTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(Te6edf3delayTb4b4b4)
T8b949e# Check if still ringing and no other active call
Te6edf3telephone Tff7b72= Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8fftelephone
Tff7b72if Tff7b72not Te6edf3telephoneTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: No telephone objectTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72return
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Checking status. Call status: Tffd700{Te6edf3telephoneTff7b72.Td2a8ffcall_statusTffd700}Ta5d6ff, Active call: Tffd700{Te6edf3telephoneTff7b72.Td2a8ffactive_callTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Te6edf3active_call_remote_identity Tff7b72= Tb4b4b4(
Te6edf3telephoneTff7b72.Td2a8ffactive_callTff7b72.Td2a8ffget_remote_identityTb4b4b4(Tb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3telephone Tff7b72and Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4)
Tff7b72else Tff7b72None
Tb4b4b4)
Tff7b72if Tb4b4b4(
Te6edf3telephone
Tff7b72and Te6edf3telephoneTff7b72.Td2a8ffactive_call
Tff7b72and Te6edf3active_call_remote_identity
Tff7b72and Te6edf3active_call_remote_identityTff7b72.Td2a8ffhash Tff7b72== Te6edf3caller_identityTff7b72.Td2a8ffhash
Tff7b72and Te6edf3telephoneTff7b72.Td2a8ffcall_status Tff7b72== T79c0ff4 T8b949e# Ringing
Tb4b4b4)Tb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffAuto-answering call from Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3caller_identityTff7b72.Td2a8ffhashTb4b4b4)Tffd700}Ta5d6ff for voicemailTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_INFOTb4b4b4,
Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffstart_voicemail_sessionTb4b4b4(Te6edf3caller_identityTb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6ff"Ta5d6ffVoicemail: Auto-answer conditions not met after delayTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72if Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Te6edf3remote_identity Tff7b72= Te6edf3telephoneTff7b72.Td2a8ffactive_callTff7b72.Td2a8ffget_remote_identityTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3remote_identityTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Active call remote: Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3remote_identityTff7b72.Td2a8ffhashTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6ff"Ta5d6ffVoicemail: Active call remote identity not foundTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Te6edf3voicemail_jobTb4b4b4, Te6edf3daemonTff7b72=Tff7b72TrueTb4b4b4)Tff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffstart_voicemail_sessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3caller_identityTb4b4b4)Tb4b4b4:
Te6edf3telephone Tff7b72= Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8fftelephone
Tff7b72if Tff7b72not Te6edf3telephoneTb4b4b4:
Tff7b72return
T8b949e# Answer the call if it's still ringing
Tff7b72if Te6edf3telephoneTff7b72.Td2a8ffcall_status Tff7b72== T79c0ff4Tb4b4b4: T8b949e# STATUS_RINGING
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffanswerTb4b4b4(Te6edf3caller_identityTb4b4b4)Tb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: Failed to answer callTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72return
Tff7b72elif Te6edf3telephoneTff7b72.Td2a8ffcall_status Tff7b72!= T79c0ff6Tb4b4b4: T8b949e# STATUS_ESTABLISHED
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Cannot start session, call status is Tffd700{Te6edf3telephoneTff7b72.Td2a8ffcall_statusTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72return
T8b949e# Stop microphone if it's active to prevent local noise being sent or recorded
Tff7b72if Te6edf3telephoneTff7b72.Td2a8ffaudio_inputTb4b4b4:
Tff7b72tryTb4b4b4:
Te6edf3telephoneTff7b72.Td2a8ffaudio_inputTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4:
Tff7b72pass
T8b949e# Play greeting
Te6edf3greeting_path Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Ta5d6ff"Ta5d6ffgreeting.opusTa5d6ff"Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3greeting_pathTb4b4b4)Tb4b4b4:
T8b949e# Fallback if no greeting generated yet
Tff7b72if Tff7b72selfTff7b72.Td2a8ffhas_espeak Tff7b72and Tff7b72selfTff7b72.Td2a8ffhas_ffmpegTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffgenerate_greetingTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_greetingTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Could not generate initial greeting: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6ff"Ta5d6ffVoicemail: espeak-ng or ffmpeg missing, cannot generate greetingTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_WARNINGTb4b4b4,
Tb4b4b4)
Tff7b72def Td2a8ffsession_jobTb4b4b4(Tb4b4b4)Tb4b4b4:
Te6edf3prev_receive_muted Tff7b72= Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8ffreceive_muted
Tff7b72tryTb4b4b4:
T8b949e# Prevent remote audio from playing locally while recording voicemail
Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8ffmute_receiveTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4:
Tff7b72pass
Tff7b72tryTb4b4b4:
T8b949e# Wait for link to stabilize
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Waiting Tffd700{Tff7b72selfTff7b72.Td2a8ffSTABILIZATION_DELAYTffd700}Ta5d6ffs for link stabilization...Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(Tff7b72selfTff7b72.Td2a8ffSTABILIZATION_DELAYTb4b4b4)
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6ff"Ta5d6ffVoicemail: Call ended during stabilization delayTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72return
T8b949e# 1. Play greeting
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3greeting_pathTb4b4b4)Tb4b4b4:
Tff7b72tryTb4b4b4:
Te6edf3greeting_source Tff7b72= Te6edf3OpusFileSourceTb4b4b4(
Te6edf3greeting_pathTb4b4b4,
Te6edf3target_frame_msTff7b72=T79c0ff60Tb4b4b4,
Tb4b4b4)
T8b949e# Attach to transmit mixer
Te6edf3greeting_pipeline Tff7b72= Te6edf3PipelineTb4b4b4(
Te6edf3sourceTff7b72=Te6edf3greeting_sourceTb4b4b4,
Te6edf3codecTff7b72=Te6edf3NullTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3sinkTff7b72=Te6edf3telephoneTff7b72.Td2a8fftransmit_mixerTb4b4b4,
Tb4b4b4)
Te6edf3greeting_pipelineTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
T8b949e# Wait for greeting to finish
Tff7b72while Te6edf3greeting_sourceTff7b72.Td2a8ffrunningTb4b4b4:
Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.1Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Te6edf3greeting_pipelineTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72return
Te6edf3greeting_pipelineTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Could not play greeting (libs missing?): Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: No greeting available to playTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_WARNINGTb4b4b4)
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Tff7b72return
T8b949e# 2. Play beep
Te6edf3beep_source Tff7b72= Te6edf3LXSTTff7b72.Td2a8ffToneSourceTb4b4b4(
Te6edf3frequencyTff7b72=T79c0ff800Tb4b4b4,
Te6edf3gainTff7b72=T79c0ff0.1Tb4b4b4,
Te6edf3target_frame_msTff7b72=T79c0ff60Tb4b4b4,
Te6edf3codecTff7b72=Te6edf3NullTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3sinkTff7b72=Te6edf3telephoneTff7b72.Td2a8fftransmit_mixerTb4b4b4,
Tb4b4b4)
Te6edf3beep_sourceTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.5Tb4b4b4)
Te6edf3beep_sourceTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Tff7b72return
T8b949e# 3. Start recording
Tff7b72selfTff7b72.Td2a8ffstart_recordingTb4b4b4(Te6edf3caller_identityTb4b4b4)
T8b949e# 4. Wait for max recording time or hangup
Te6edf3max_time Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffvoicemail_max_recording_secondsTff7b72.Td2a8ffgetTb4b4b4(Tb4b4b4)
Te6edf3start_wait Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72while Tff7b72selfTff7b72.Td2a8ffis_recording Tff7b72and Tb4b4b4(Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72- Te6edf3start_wait Tff7b72< Te6edf3max_timeTb4b4b4)Tb4b4b4:
Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.5Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Tff7b72break
T8b949e# 5. End session
Tff7b72if Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Te6edf3telephoneTff7b72.Td2a8ffhangupTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffstop_recordingTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffError during voicemail session: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffis_recordingTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffstop_recordingTb4b4b4(Tb4b4b4)
Tff7b72finallyTb4b4b4:
Tff7b72tryTb4b4b4:
Tff7b72if Tff7b72not Te6edf3prev_receive_mutedTb4b4b4:
Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8ffunmute_receiveTb4b4b4(Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4:
Tff7b72pass
Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Te6edf3session_jobTb4b4b4, Te6edf3daemonTff7b72=Tff7b72TrueTb4b4b4)Tff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffstart_recordingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3caller_identityTb4b4b4)Tb4b4b4:
Te6edf3telephone Tff7b72= Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8fftelephone
Tff7b72if Tff7b72not Te6edf3telephone Tff7b72or Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffactive_callTb4b4b4:
Tff7b72return
Te6edf3timestamp Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Te6edf3filename Tff7b72= Ta5d6fffTa5d6ff"Ta5d6ffvoicemail_Tffd700{Te6edf3caller_identityTff7b72.Td2a8ffhashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tffd700}Ta5d6ff_Tffd700{Tffa657intTb4b4b4(Te6edf3timestampTb4b4b4)Tffd700}Ta5d6ff.opusTa5d6ff"
Te6edf3filepath Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrecordings_dirTb4b4b4, Te6edf3filenameTb4b4b4)
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffrecording_sink Tff7b72= Te6edf3OpusFileSinkTb4b4b4(Te6edf3filepathTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffrecording_sinkTff7b72.Td2a8ffsamplerate Tff7b72= T79c0ff48000
Tff7b72selfTff7b72.Td2a8ffrecording_pipeline Tff7b72= Te6edf3PipelineTb4b4b4(
Te6edf3telephoneTff7b72.Td2a8ffactive_callTff7b72.Td2a8ffaudio_sourceTb4b4b4,
Te6edf3NullTb4b4b4(Tb4b4b4)Tb4b4b4,
Tff7b72selfTff7b72.Td2a8ffrecording_sinkTb4b4b4,
Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffrecording_pipelineTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffis_recording Tff7b72= Tff7b72True
Tff7b72selfTff7b72.Td2a8ffrecording_start_time Tff7b72= Te6edf3timestamp
Tff7b72selfTff7b72.Td2a8ffrecording_remote_identity Tff7b72= Te6edf3caller_identity
Tff7b72selfTff7b72.Td2a8ffrecording_filename Tff7b72= Te6edf3filename
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffStarted recording voicemail from Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3caller_identityTff7b72.Td2a8ffhashTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffFailed to start recording: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72def Td2a8ffstop_recordingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffis_recordingTb4b4b4:
Tff7b72return
Tff7b72tryTb4b4b4:
Te6edf3duration Tff7b72= Tffa657intTb4b4b4(Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72- Tff7b72selfTff7b72.Td2a8ffrecording_start_timeTb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffrecording_pipelineTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffrecording_pipelineTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffrecording_sinkTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffrecording_sinkTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffrecording_sink Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_pipeline Tff7b72= Tff7b72None
T8b949e# Save to database if long enough
Tff7b72if Te6edf3duration Tff7b72>Tff7b72= T79c0ff1Tb4b4b4:
Te6edf3filepath Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrecordings_dirTb4b4b4, Tff7b72selfTff7b72.Td2a8ffrecording_filenameTb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_fix_recordingTb4b4b4(Te6edf3filepathTb4b4b4)
T8b949e# If recording is missing or empty (no frames), synthesize a small silence file
Tff7b72if Tb4b4b4(Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4) Tff7b72or Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffgetsizeTb4b4b4(Te6edf3filepathTb4b4b4) Tff7b72== T79c0ff0Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_write_silence_fileTb4b4b4(Te6edf3filepathTb4b4b4, Tffa657maxTb4b4b4(Te6edf3durationTb4b4b4, T79c0ff1Tb4b4b4)Tb4b4b4)
Te6edf3remote_name Tff7b72= Tff7b72selfTff7b72.Td2a8ffget_name_for_identity_hashTb4b4b4(
Tff7b72selfTff7b72.Td2a8ffrecording_remote_identityTff7b72.Td2a8ffhashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3filepathTb4b4b4) Tff7b72and Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffgetsizeTb4b4b4(Te6edf3filepathTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffdbTff7b72.Td2a8ffvoicemailsTff7b72.Td2a8ffadd_voicemailTb4b4b4(
Te6edf3remote_identity_hashTff7b72=Tff7b72selfTff7b72.Td2a8ffrecording_remote_identityTff7b72.Td2a8ffhashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3remote_identity_nameTff7b72=Te6edf3remote_nameTb4b4b4,
Te6edf3filenameTff7b72=Tff7b72selfTff7b72.Td2a8ffrecording_filenameTb4b4b4,
Te6edf3duration_secondsTff7b72=Te6edf3durationTb4b4b4,
Te6edf3timestampTff7b72=Tff7b72selfTff7b72.Td2a8ffrecording_start_timeTb4b4b4,
Tb4b4b4)
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffSaved voicemail from Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrecording_remote_identityTff7b72.Td2a8ffhashTb4b4b4)Tffd700}Ta5d6ff (Tffd700{Te6edf3durationTffd700}Ta5d6ffs)Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Recording missing for Tffd700{Tff7b72selfTff7b72.Td2a8ffrecording_filenameTffd700}Ta5d6ff, skipping DB insertTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffon_new_voicemail_callbackTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffon_new_voicemail_callbackTb4b4b4(
Tff7b72selfTff7b72.Td2a8ffrecording_remote_identityTff7b72.Td2a8ffhashTff7b72.Td2a8ffhexTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3remote_nameTb4b4b4,
Te6edf3durationTb4b4b4,
Tb4b4b4)
Tff7b72elseTb4b4b4:
T8b949e# Delete short/empty recording
Te6edf3filepath Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffrecordings_dirTb4b4b4, Tff7b72selfTff7b72.Td2a8ffrecording_filenameTb4b4b4)
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3filepathTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffis_recording Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ffis_greeting_recording Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ffrecording_start_time Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_remote_identity Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffrecording_filename Tff7b72= Tff7b72None
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffError stopping recording: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffis_recording Tff7b72= Tff7b72False
Tff7b72def Td2a8ff_fix_recordingTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3filepathTb4b4b4)Tb4b4b4:
T8b949e"""Ensures the recording is a valid OGG/Opus file using ffmpeg."""
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffhas_ffmpeg Tff7b72or Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4:
Tff7b72return
Te6edf3temp_path Tff7b72= Te6edf3filepath Tff7b72+ Ta5d6ff"Ta5d6ff.fixTa5d6ff"
Tff7b72tryTb4b4b4:
T8b949e# We assume it might be raw opus packets or a slightly broken ogg
T8b949e# ffmpeg can often fix this by just re-wrapping it.
T8b949e# We try to detect if it's already a valid format first.
Te6edf3cmd Tff7b72= Tb4b4b4[
Tff7b72selfTff7b72.Td2a8ffffmpeg_pathTb4b4b4,
Ta5d6ff"Ta5d6ff-yTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-iTa5d6ff"Tb4b4b4,
Te6edf3filepathTb4b4b4,
Ta5d6ff"Ta5d6ff-c:aTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6fflibopusTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-b:aTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff16kTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-arTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff48000Ta5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-acTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff1Ta5d6ff"Tb4b4b4,
Te6edf3temp_pathTb4b4b4,
Tb4b4b4]
Te6edf3result Tff7b72= Te6edf3subprocessTff7b72.Td2a8ffrunTb4b4b4(Te6edf3cmdTb4b4b4, Te6edf3capture_outputTff7b72=Tff7b72TrueTb4b4b4, Te6edf3textTff7b72=Tff7b72TrueTb4b4b4, Te6edf3checkTff7b72=Tff7b72FalseTb4b4b4) T8b949e# noqa: S603
Tff7b72if Te6edf3resultTff7b72.Td2a8ffreturncode Tff7b72== T79c0ff0 Tff7b72and Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3temp_pathTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3filepathTb4b4b4)
Te6edf3osTff7b72.Td2a8ffrenameTb4b4b4(Te6edf3temp_pathTb4b4b4, Te6edf3filepathTb4b4b4)
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Fixed recording format for Tffd700{Te6edf3filepathTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4,
Tb4b4b4)
Tff7b72elseTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: ffmpeg failed to fix Tffd700{Te6edf3filepathTffd700}Ta5d6ff: Tffd700{Te6edf3resultTff7b72.Td2a8ffstderrTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_WARNINGTb4b4b4,
Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Error fixing recording Tffd700{Te6edf3filepathTffd700}Ta5d6ff: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72finallyTb4b4b4:
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3temp_pathTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3temp_pathTb4b4b4)
Tff7b72def Td2a8ff_write_silence_fileTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3filepathTb4b4b4, Te6edf3secondsTff7b72=T79c0ff1Tb4b4b4)Tb4b4b4:
T8b949e"""Creates a minimal OGG/Opus file with silence if recording is missing."""
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffhas_ffmpegTb4b4b4:
Tff7b72return Tff7b72False
Tff7b72tryTb4b4b4:
Te6edf3cmd Tff7b72= Tb4b4b4[
Tff7b72selfTff7b72.Td2a8ffffmpeg_pathTb4b4b4,
Ta5d6ff"Ta5d6ff-yTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-fTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6fflavfiTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-iTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ffanullsrc=r=48000:cl=monoTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-tTa5d6ff"Tb4b4b4,
Tffa657strTb4b4b4(Tffa657maxTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3secondsTb4b4b4)Tb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ff-c:aTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6fflibopusTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff-b:aTa5d6ff"Tb4b4b4,
Ta5d6ff"Ta5d6ff16kTa5d6ff"Tb4b4b4,
Te6edf3filepathTb4b4b4,
Tb4b4b4]
Te6edf3result Tff7b72= Te6edf3subprocessTff7b72.Td2a8ffrunTb4b4b4(Te6edf3cmdTb4b4b4, Te6edf3capture_outputTff7b72=Tff7b72TrueTb4b4b4, Te6edf3textTff7b72=Tff7b72TrueTb4b4b4, Te6edf3checkTff7b72=Tff7b72FalseTb4b4b4) T8b949e# noqa: S603
Tff7b72if Te6edf3resultTff7b72.Td2a8ffreturncode Tff7b72== T79c0ff0 Tff7b72and Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4:
Tff7b72return Tff7b72True
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Failed to create silence file for Tffd700{Te6edf3filepathTffd700}Ta5d6ff: Tffd700{Te6edf3resultTff7b72.Td2a8ffstderrTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Error creating silence file for Tffd700{Te6edf3filepathTffd700}Ta5d6ff: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72return Tff7b72False
Tff7b72def Td2a8ffstart_greeting_recordingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3telephone Tff7b72= Tff7b72selfTff7b72.Td2a8fftelephone_managerTff7b72.Td2a8fftelephone
Tff7b72if Tff7b72not Te6edf3telephoneTb4b4b4:
Tff7b72return
T8b949e# Ensure we have audio input
Tff7b72if Tff7b72not Te6edf3telephoneTff7b72.Td2a8ffaudio_inputTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6ff"Ta5d6ffVoicemail: No audio input available for recording greetingTa5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72return
Te6edf3temp_wav Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Ta5d6ff"Ta5d6fftemp_greeting.wavTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3temp_wavTb4b4b4)Tb4b4b4:
Te6edf3osTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3temp_wavTb4b4b4)
Tff7b72tryTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_sink Tff7b72= Te6edf3OpusFileSinkTb4b4b4(
Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffgreetings_dirTb4b4b4, Ta5d6ff"Ta5d6ffgreeting.opusTa5d6ff"Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_sinkTff7b72.Td2a8ffsamplerate Tff7b72= T79c0ff48000
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_pipeline Tff7b72= Te6edf3PipelineTb4b4b4(
Te6edf3telephoneTff7b72.Td2a8ffaudio_inputTb4b4b4,
Te6edf3NullTb4b4b4(Tb4b4b4)Tb4b4b4,
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_sinkTb4b4b4,
Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_pipelineTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffis_greeting_recording Tff7b72= Tff7b72True
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: Started recording greeting from micTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(
Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Failed to start greeting recording: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4,
Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4,
Tb4b4b4)
Tff7b72def Td2a8ffstop_greeting_recordingTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffis_greeting_recordingTb4b4b4:
Tff7b72return
Tff7b72tryTb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8ffgreeting_recording_pipelineTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_pipelineTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ffgreeting_recording_sinkTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_sinkTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_sink Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffgreeting_recording_pipeline Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ffis_greeting_recording Tff7b72= Tff7b72False
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffVoicemail: Stopped recording greeting from micTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)
Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:
Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffVoicemail: Error stopping greeting recording: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffis_greeting_recording Tff7b72= Tff7b72False
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────